package com.xxk.rocket.star.core.client;

import com.alibaba.rocketmq.client.producer.MQProducer;
import com.xxk.rocket.star.core.context.ProducerContext;

public interface IProcessClientProducer {

  void processProducerByContext(ProducerContext producerContext, MQProducer mqProducer)
          throws Throwable;

}
